package com.example.iot.service.ts;

import com.example.iot.entity.dto.TsData;
import com.google.common.util.concurrent.ListenableFuture;

import java.util.List;
import java.util.concurrent.Executor;

/**
 * 异步方法
 * @author ChenXiangpeng
 */
public interface TimeSeriesService {
    /**
     * 保存数据
     * @param deviceId 设备ID
     * @param data 数据
     */
    void save(String deviceId, TsData data);

    /**
     * 异步执行查询最新消息
     * @param entityId id
     * @param executor 线程池
     * @return com.google.common.util.concurrent.ListenableFuture<java.util.List<com.example.iot.entity.dto.TsData>>
     */
    ListenableFuture<List<TsData>> getAllLatest(String entityId, Executor executor);
}
